565c57e433d9adef085fc227288b052b2fa0e1cb,cdap-hbase-compat-0.98/src/main/java/co/cask/cdap/data2/increment/hbase98/IncrementHandler.java,IncrementHandler,preCompact,#ObserverContext#Store#InternalScanner#ScanType#,175

Before Change


  public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store,
                                    InternalScanner scanner, ScanType scanType) throws IOException {
    TransactionSnapshot snapshot = cache.getLatestState();
    if (snapshot != null) {
      return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner, snapshot.getVisibilityUpperBound());
    }
    return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner);
  }

  @Override

After Change


  public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store,
                                    InternalScanner scanner, ScanType scanType) throws IOException {
    TransactionSnapshot snapshot = cache.getLatestState();
    return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner, scanType,
        snapshot != null ? snapshot.getVisibilityUpperBound() : 0);
  }

  @Override